package com.wdd.flinkdemo.frauddemo;

import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.apache.flink.walkthrough.common.entity.Alert;

/**
 * @author Administrator
 */
public class MyAlertSink implements SinkFunction<Alert> {
    @Override
    public void invoke(Alert value, Context context) throws Exception {
        System.out.println(value);
    }
}
